//package com.yuxi.configcenter;
//
//import org.I0Itec.zkclient.IZkDataListener;
//import org.I0Itec.zkclient.ZkClient;
//
//import java.util.concurrent.TimeUnit;
//
///**
// * Created by yuxi on 16/11/19.
// */
//public class ClientApp {
//    FtpConfig ftpConfig;
//    private FtpConfig getFtpConfig() {
//        if (ftpConfig==null) {
//            ZkClient zkClient = ZkUtil.getClient();
//            ftpConfig = zkClient.readData(ZkUtil.FTP_CONFIG_NODE_NAME);
//            zkClient.subscribeDataChanges(ZkUtil.FTP_CONFIG_NODE_NAME, new IZkDataListener() {
//                @Override
//                public void handleDataChange(String s, Object o) throws Exception {
//                    ftpConfig = (FtpConfig) o;//重新加载FtpConfig
//                }
//                @Override
//                public void handleDataDeleted(String s) throws Exception {
//                    ftpConfig = null;
//                }
//            });
//        }
//        return  ftpConfig;
//    }
//    /**
//     * 模拟程序运行
//     *
//     * @throws InterruptedException
//     */
//    public void run() throws InterruptedException {
//        getFtpConfig();
//        upload();
//        download();
//    }
//    public void upload() throws InterruptedException {
//        System.out.println(ftpConfig);
//        TimeUnit.SECONDS.sleep(10);
//    }
//    public void download() throws InterruptedException {
//        System.out.println(ftpConfig);
//        TimeUnit.SECONDS.sleep(10);
//    }
//}
